package com.yanduo.tags

import org.apache.commons.lang3.StringUtils
import org.apache.spark.sql.Row

/**
  * 广告标签
  *
  * @author Gerry chan
  * 220/5/5 11:09
  * @version 1.0
  */
object Tags4Ads extends Tags {
  /**
    * 打标签方法
    * @param args
    * @return
    */
  override def makeTags(args: Any*): Map[String, Int] = {

    var map = Map[String, Int]()

    //将参数转换成Row 对象
    val row = args(0).asInstanceOf[Row]
    // 广告为类型和名称
    val adTypeId = row.getAs[Int]("adspacetype")
    val adTypeName = row.getAs[String]("adspacetypename")

    if (adTypeId > 9) map += "LC"+adTypeId ->1
    else if(adTypeId >0) map +="LC0"+adTypeId ->1

    if (StringUtils.isNotEmpty(adTypeName)) map += "LN" +adTypeName -> 1

    map

  }
}
